<?php
require_once APPPATH."third_party/wxpayapi/lib/WxPay.Api.php";
require_once APPPATH."third_party/wxpayapi/lib/WxPay.Notify.php";
require_once APPPATH."third_party/wxpayapi/lib/log.php";

class Wxpaynotifycallback extends WxPayNotify
{
    private $CI;

    public function __construct()
    {
        $this->CI = &get_instance();
    }

    //查询订单
    public function Queryorder($transaction_id)
    {
        $input = new WxPayOrderQuery();
        $input->SetTransaction_id($transaction_id);
        $result = WxPayApi::orderQuery($input);
        Log::DEBUG("query:" . json_encode($result));
        if(array_key_exists("return_code", $result)
            && array_key_exists("result_code", $result)
            && $result["return_code"] == "SUCCESS"
            && $result["result_code"] == "SUCCESS")
        {
            return true;
        }
        return false;
    }

    //重写回调处理函数
    public function NotifyProcess($data, &$msg)
    {
        if(!array_key_exists("transaction_id", $data)){
            $msg = "输入参数不正确";
            return false;
        }
        //查询订单，判断订单真实性
        if(!$this->Queryorder($data["transaction_id"])){
            $msg = "订单查询失败";
            return false;
        }

        $datastr = igbinary_serialize($data);
        if (!empty($data['attach'])){
            $format = explode('|',$data['attach']);
            $num = trim($format[0]);
            $uid = trim($format[1]);
            $this->CI->load->model('redis_model');
            $redis = $this->CI->redis_model->getRedisInstance();
            $redis->multi();
            $redis->rPush('wxpaytrans',$datastr);
            $redis->incrby('user:'.$uid.'.beans',$num);
            $redis->exec();
        }

        return true;
    }
}